package com.dtwave.lnstreaming.filter;

import com.alibaba.fastjson.JSONObject;
import com.dtwave.lnstreaming.filter.function.FlatMapFunction;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;

public class StreamDataSplit {

    public static SingleOutputStreamOperator<JSONObject> fitler(DataStream<String> kafkaDataStream) {
        return kafkaDataStream.flatMap(new FlatMapFunction());
    }

}
